package scs.service;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.stereotype.Component;
import scs.channel.InputChannel2;

/**
 * @description : TODO
 * @author: guangrui_hu
 * @date: 2023/1/11
 * @version:
 */
@Component
@EnableBinding(InputChannel2.class)
public class Recevier {
    @StreamListener(InputChannel2.input)
    public void receive(String message) {
        System.out.println("消费者2接收到的消息为 = " + message);
    }
}
